Micron Document
🎖️GitЯра🎖️

Node / meshtastic / Meshtastic-Android / files / core / data / src / commonMain / kotlin / org / meshtastic / core / data / manager / MeshMessageProcessorImpl.kt

Displaying Raw • Download

core/data/src/commonMain/kotlin/org/meshtastic/core/data/manager/MeshMessageProcessorImpl.kt 2d20cd8a4708e2ef66e98d5259f3a97ec93f240a (2d20cd8a) Text, 19.09 KB

T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787co.touchlab.kermit.Logger
Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope
Tff7b72import T7ee787kotlinx.coroutines.CoroutineStart
Tff7b72import T7ee787kotlinx.coroutines.Job
Tff7b72import T7ee787kotlinx.coroutines.flow.combine
Tff7b72import T7ee787kotlinx.coroutines.flow.distinctUntilChanged
Tff7b72import T7ee787kotlinx.coroutines.flow.launchIn
Tff7b72import T7ee787kotlinx.coroutines.flow.onEach
Tff7b72import T7ee787kotlinx.coroutines.launch
Tff7b72import T7ee787kotlinx.coroutines.sync.Mutex
Tff7b72import T7ee787kotlinx.coroutines.sync.withLock
Tff7b72import T7ee787org.koin.core.annotation.Named
Tff7b72import T7ee787org.koin.core.annotation.Single
Tff7b72import T7ee787org.meshtastic.core.common.util.clampTimestampToNow
Tff7b72import T7ee787org.meshtastic.core.common.util.handledLaunch
Tff7b72import T7ee787org.meshtastic.core.common.util.nowMillis
Tff7b72import T7ee787org.meshtastic.core.common.util.nowSeconds
Tff7b72import T7ee787org.meshtastic.core.common.util.safeCatching
Tff7b72import T7ee787org.meshtastic.core.model.MeshLog
Tff7b72import T7ee787org.meshtastic.core.model.Node
Tff7b72import T7ee787org.meshtastic.core.model.util.isLora
Tff7b72import T7ee787org.meshtastic.core.model.util.rxTimeOrNull
Tff7b72import T7ee787org.meshtastic.core.model.util.snrOrNull
Tff7b72import T7ee787org.meshtastic.core.model.util.toOneLineString
Tff7b72import T7ee787org.meshtastic.core.model.util.toPIIString
Tff7b72import T7ee787org.meshtastic.core.repository.FromRadioPacketHandler
Tff7b72import T7ee787org.meshtastic.core.repository.MeshDataHandler
Tff7b72import T7ee787org.meshtastic.core.repository.MeshLogRepository
Tff7b72import T7ee787org.meshtastic.core.repository.MeshMessageProcessor
Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager
Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService
Tff7b72import T7ee787org.meshtastic.core.repository.RadioSessionContext
Tff7b72import T7ee787org.meshtastic.core.repository.ReceivedRadioFrame
Tff7b72import T7ee787org.meshtastic.core.repository.ServiceStateWriter
Tff7b72import T7ee787org.meshtastic.proto.FromRadio
Tff7b72import T7ee787org.meshtastic.proto.LogRecord
Tff7b72import T7ee787org.meshtastic.proto.MeshPacket
Tff7b72import T7ee787org.meshtastic.proto.PortNum
Tff7b72import T7ee787kotlin.concurrent.Volatile
Tff7b72import T7ee787kotlin.uuid.Uuid

T8b949e/** Implementation of [MeshMessageProcessor] that handles raw radio messages and prepares mesh packets for routing. */
Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)
Tf0883e@Single
Tff7b72class T56d364MeshMessageProcessorImplTb4b4b4(
Tff7b72private Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,
Tff7b72private Tff7b72val Te6edf3serviceStateWriterTb4b4b4: Te6edf3ServiceStateWriterTb4b4b4,
Tff7b72private Tff7b72val Te6edf3meshLogRepositoryTb4b4b4: Te6edf3LazyTff7b72<Te6edf3MeshLogRepositoryTff7b72>Tb4b4b4,
Tff7b72private Tff7b72val Te6edf3dataHandlerTb4b4b4: Te6edf3LazyTff7b72<Te6edf3MeshDataHandlerTff7b72>Tb4b4b4,
Tff7b72private Tff7b72val Te6edf3fromRadioDispatcherTb4b4b4: Te6edf3FromRadioPacketHandlerTb4b4b4,
Tff7b72private Tff7b72val Te6edf3radioInterfaceServiceTb4b4b4: Te6edf3RadioInterfaceServiceTb4b4b4,
Tf0883e@NamedTb4b4b4(Ta5d6ff"Ta5d6ffServiceScopeTa5d6ff"Tb4b4b4) Tff7b72private Tff7b72val Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4,
Tb4b4b4) Tb4b4b4: Te6edf3MeshMessageProcessor Tb4b4b4{

T8b949e/**
* Epoch-millisecond timestamp of the last local-node `lastHeard` DB write. Used to throttle updates to at most once
* per [LOCAL_NODE_REFRESH_INTERVAL_MS] so that high-frequency FromRadio variants (log records, queue status) don't
* flood the DB.
*/
Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3lastLocalNodeRefreshMs Tff7b72= T79c0ff0L

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3lastLocalNodeRefreshGeneration Tff7b72= Tffa657LongTb4b4b4.Te6edf3MIN_VALUE

Tff7b72private Tff7b72data Tff7b72class T56d364BufferedMeshPacketTb4b4b4(Tff7b72val Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Tff7b72val Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4)

Tff7b72private Tff7b72val Te6edf3earlyMutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3earlyFlushMutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3earlyReceivedPackets Tff7b72= Te6edf3ArrayDequeTff7b72<Te6edf3BufferedMeshPacketTff7b72>Tb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3maxEarlyPacketBuffer Tff7b72= T79c0ff1T79c0ff0T79c0ff2T79c0ff4T79c0ff0

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffclearEarlyPacketsTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3earlyFlushMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}

Tff7b72init Tb4b4b4{
T8b949e// Flush buffered packets only once BOTH the node DB is ready AND our own node number is known. Processing a
T8b949e// received packet while myNodeNum is still null would key a local packet under its raw from_num instead of
T8b949e// NODE_NUM_LOCAL (see [handleReceivedMeshPacket] / [processReceivedMeshPacket]), orphaning it from per-node
T8b949e// queries. Emit the (ready, myNodeNum) pair — not the derived boolean — so distinctUntilChanged re-fires on
T8b949e// every underlying state change (including a reconnect where myNodeNum transitions null -> value) rather than
T8b949e// collapsing distinct states that happen to map to the same boolean.
Te6edf3combineTb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReadyTb4b4b4, Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4) Tb4b4b4{ Te6edf3readyTb4b4b4, Te6edf3myNodeNum Tff7b72-Tff7b72> Te6edf3ready Te6edf3to Te6edf3myNodeNum Tb4b4b4}
Tb4b4b4.Te6edf3distinctUntilChangedTb4b4b4(Tb4b4b4)
Tb4b4b4.Te6edf3onEach Tb4b4b4{ Tb4b4b4(Te6edf3readyTb4b4b4, Te6edf3myNodeNumTb4b4b4) Tff7b72-Tff7b72>
Tff7b72if Tb4b4b4(Te6edf3ready Tff7b72&Tff7b72& Te6edf3myNodeNum Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3flushEarlyReceivedPacketsTb4b4b4(Ta5d6ff"Ta5d6ffreadyTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3scopeTb4b4b4)
Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffhandleFromRadioTb4b4b4(Te6edf3frameTb4b4b4: Te6edf3ReceivedRadioFrameTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3isSessionActiveTb4b4b4(Te6edf3frameTb4b4b4.Te6edf3sessionTb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffDropping decoded work from stale transport session gen=Tffd700${Te6edf3frameTb4b4b4.Te6edf3sessionTb4b4b4.Te6edf3generationTffd700}Ta5d6ff" Tb4b4b4}
Tff7b72return
Tb4b4b4}
Tff7b72val Te6edf3bytes Tff7b72= Te6edf3frameTb4b4b4.Te6edf3payloadTb4b4b4.Te6edf3toByteArrayTb4b4b4(Tb4b4b4)
Tff7b72val Te6edf3proto Tff7b72=
Te6edf3safeCatching Tb4b4b4{ Te6edf3FromRadioTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3bytesTb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3getOrElse Tb4b4b4{ Te6edf3primaryException Tff7b72-Tff7b72>
Te6edf3safeCatching Tb4b4b4{ Te6edf3FromRadioTb4b4b4(Te6edf3log_record Tff7b72= Te6edf3LogRecordTb4b4b4.Te6edf3ADAPTERTb4b4b4.Te6edf3decodeTb4b4b4(Te6edf3bytesTb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3getOrElse Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3primaryExceptionTb4b4b4) Tb4b4b4{
Ta5d6ff"Ta5d6ffFailed to parse radio packet (len=Tffd700${Te6edf3bytesTb4b4b4.Te6edf3sizeTffd700}Ta5d6ff). Not a valid FromRadio or LogRecord.Ta5d6ff"
Tb4b4b4}
Tff7b72return
Tb4b4b4}
Tb4b4b4}
Te6edf3processFromRadioTb4b4b4(Te6edf3protoTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3frameTb4b4b4.Te6edf3sessionTb4b4b4)
Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffprocessFromRadioTb4b4b4(Te6edf3protoTb4b4b4: Te6edf3FromRadioTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4, Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3admitted Tff7b72=
Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3runWhileSessionActiveTb4b4b4(Te6edf3sessionTb4b4b4) Tb4b4b4{
Te6edf3safeCatching Tb4b4b4{
T8b949e// Audit log every incoming variant without allowing delayed work to cross a session boundary.
Te6edf3logVariantTb4b4b4(Te6edf3protoTb4b4b4, Te6edf3sessionTb4b4b4)

Tff7b72val Te6edf3packet Tff7b72= Te6edf3protoTb4b4b4.Te6edf3packet
Tff7b72if Tb4b4b4(Te6edf3packet Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3handleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3sessionTb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
T8b949e// Packets refresh the local node in processReceivedMeshPacket; other variants need the
T8b949e// heartbeat.
Te6edf3refreshLocalNodeLastHeardTb4b4b4(Te6edf3sessionTb4b4b4)
Te6edf3fromRadioDispatcherTb4b4b4.Te6edf3handleFromRadioTb4b4b4(Te6edf3protoTb4b4b4, Te6edf3sessionTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4.Te6edf3onFailure Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffDropped a FromRadio after a handler error; receive pipeline kept aliveTa5d6ff" Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3admittedTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffDropping FromRadio from stale transport session gen=Tffd700${Te6edf3sessionTb4b4b4.Te6edf3generationTffd700}Ta5d6ff" Tb4b4b4}
Tb4b4b4}
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8fflogVariantTb4b4b4(Te6edf3protoTb4b4b4: Te6edf3FromRadioTb4b4b4, Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4) Tb4b4b4{
Tff7b72val Tb4b4b4(Te6edf3typeTb4b4b4, Te6edf3messageTb4b4b4) Tff7b72=
Tff7b72when Tb4b4b4{
Te6edf3protoTb4b4b4.Te6edf3log_record Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffLogRecordTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3log_recordTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3rebooted Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffRebootedTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3rebootedTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3xmodemPacket Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffXmodemPacketTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3xmodemPacketTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3deviceuiConfig Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffDeviceUIConfigTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3deviceuiConfigTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3fileInfo Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffFileInfoTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3fileInfoTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3my_info Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffMyInfoTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3my_infoTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3node_info Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffNodeInfoTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3node_infoTff7b72!!Tb4b4b4.Te6edf3toPIIStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3config Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffConfigTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3configTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3moduleConfig Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffModuleConfigTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3moduleConfigTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3channel Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffChannelTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3channelTff7b72!!Tb4b4b4.Te6edf3toOneLineStringTb4b4b4(Tb4b4b4)
Te6edf3protoTb4b4b4.Te6edf3clientNotification Tff7b72!Tff7b72= Tff7b72null Tff7b72-Tff7b72> Ta5d6ff"Ta5d6ffClientNotificationTa5d6ff" Te6edf3to Te6edf3protoTb4b4b4.Te6edf3clientNotificationTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)
Tff7b72else Tff7b72-Tff7b72> Tff7b72return
Tb4b4b4}

Te6edf3insertMeshLogTb4b4b4(
Te6edf3MeshLogTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3UuidTb4b4b4.Te6edf3randomTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3message_type Tff7b72= Te6edf3typeTb4b4b4,
Te6edf3received_date Tff7b72= Te6edf3nowMillisTb4b4b4,
Te6edf3raw_message Tff7b72= Te6edf3messageTb4b4b4,
Te6edf3fromRadio Tff7b72= Te6edf3protoTb4b4b4,
Tb4b4b4)Tb4b4b4,
Te6edf3sessionTb4b4b4,
Tb4b4b4)
Tb4b4b4}

T8b949e/** Test seam for packet-only fixtures with explicit transport authority. */
Tff7b72internal Tff7b72suspend Tff7b72fun Td2a8ffhandleReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657Int?Tb4b4b4, Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4) Tb4b4b4{
T8b949e// Single normalization point: every consumer downstream of this copy sees a stamped packet.
Tff7b72val Te6edf3preparedPacket Tff7b72= Te6edf3packetTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3rx_time Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rxTimeOrNullTb4b4b4(Tb4b4b4) Tff7b72?: Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)

T8b949e// Require myNodeNum to be known before storing: processReceivedMeshPacket only keys a local packet under
T8b949e// NODE_NUM_LOCAL when packet.from == myNodeNum. If myNodeNum is still null (early in a (re)connect, before
T8b949e// MyNodeInfo resolves), a local packet would be stored under its raw from_num and become invisible to
T8b949e// per-node chart queries while still appearing in the unfiltered Debug log. Buffer until both are ready;
T8b949e// the init combine flushes the buffer once myNodeNum resolves.
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3isSessionActiveTb4b4b4(Te6edf3sessionTb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffDropping mesh packet from stale transport session gen=Tffd700${Te6edf3sessionTb4b4b4.Te6edf3generationTffd700}Ta5d6ff" Tb4b4b4}
Tff7b72return
Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72&Tff7b72& Te6edf3myNodeNum Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3processReceivedMeshPacketTb4b4b4(Te6edf3preparedPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3sessionTb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
T8b949e// Production callers already hold the session lease in processFromRadio. Enqueue directly so packet FIFO
T8b949e// does not depend on the ordering of separately launched mutex waiters.
Te6edf3enqueueBufferedPacketTb4b4b4(Te6edf3BufferedMeshPacketTb4b4b4(Te6edf3preparedPacketTb4b4b4, Te6edf3sessionTb4b4b4)Tb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72&Tff7b72& Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3flushEarlyReceivedPacketsTb4b4b4(Ta5d6ff"Ta5d6ffenqueue-readyTa5d6ff"Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffenqueueBufferedPacketTb4b4b4(Te6edf3bufferedTb4b4b4: Te6edf3BufferedMeshPacketTb4b4b4) Tff7b72= Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{
Te6edf3discardBufferedPacketsFromOtherSessionsTb4b4b4(Te6edf3bufferedTb4b4b4.Te6edf3sessionTb4b4b4)
Tff7b72val Te6edf3queueSize Tff7b72= Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3size
Tff7b72if Tb4b4b4(Te6edf3queueSize Tff7b72>Tff7b72= Te6edf3maxEarlyPacketBufferTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffEarly packet buffer full (Tffd700$Te6edf3queueSizeTa5d6ff), dropping oldest packetTa5d6ff" Tb4b4b4}
Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3removeFirstOrNullTb4b4b4(Tb4b4b4)
Tb4b4b4}
Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3addLastTb4b4b4(Te6edf3bufferedTb4b4b4)
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffdiscardBufferedPacketsFromOtherSessionsTb4b4b4(Te6edf3activeSessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3removed Tff7b72= Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3removeAll Tb4b4b4{ Te6edf3queued Tff7b72-Tff7b72> Te6edf3queuedTb4b4b4.Te6edf3session Tff7b72!Tff7b72= Te6edf3activeSession Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3removedTb4b4b4) Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffDiscarded buffered packets from an earlier transport generationTa5d6ff" Tb4b4b4}
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffflushEarlyReceivedPacketsTb4b4b4(Te6edf3reasonTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{
Te6edf3scopeTb4b4b4.Te6edf3launch Tb4b4b4{ Te6edf3earlyFlushMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3replayEarlyReceivedPacketsTb4b4b4(Te6edf3reasonTb4b4b4) Tb4b4b4} Tb4b4b4}
Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffreplayEarlyReceivedPacketsTb4b4b4(Te6edf3reasonTb4b4b4: Tffa657StringTb4b4b4) Tb4b4b4{
Tff7b72var Te6edf3replayed Tff7b72= T79c0ff0
Tff7b72while Tb4b4b4(Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReadyTb4b4b4.Te6edf3valueTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3myNodeNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return
Tff7b72val Te6edf3buffered Tff7b72= Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3removeFirstOrNullTb4b4b4(Tb4b4b4) Tb4b4b4} Tff7b72?: Tff7b72break

T8b949e// Readiness can regress while a queued flush waits behind an earlier replay. Put the packet back at the
T8b949e// front instead of keying it against a database that is being cleared or an unresolved local node number.
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3isReplayReadyTb4b4b4(Te6edf3myNodeNumTb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3earlyMutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3earlyReceivedPacketsTb4b4b4.Te6edf3addFirstTb4b4b4(Te6edf3bufferedTb4b4b4) Tb4b4b4}
Tff7b72return
Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3processBufferedPacketTb4b4b4(Te6edf3bufferedTb4b4b4, Te6edf3myNodeNumTb4b4b4)Tb4b4b4) Te6edf3replayed Tff7b72+Tff7b72= T79c0ff1
Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3replayed Tff7b72> T79c0ff0Tb4b4b4) Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffreplayEarlyPackets reason=Tffd700$Te6edf3reasonTa5d6ff count=Tffd700$Te6edf3replayedTa5d6ff" Tb4b4b4}
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffisReplayReadyTb4b4b4(Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72=
Te6edf3nodeManagerTb4b4b4.Te6edf3isNodeDbReadyTb4b4b4.Te6edf3value Tff7b72&Tff7b72& Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72=Tff7b72= Te6edf3myNodeNum

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffprocessBufferedPacketTb4b4b4(Te6edf3bufferedTb4b4b4: Te6edf3BufferedMeshPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{
Tff7b72val Te6edf3admitted Tff7b72=
Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3runWhileSessionActiveTb4b4b4(Te6edf3bufferedTb4b4b4.Te6edf3sessionTb4b4b4) Tb4b4b4{
Te6edf3safeCatching Tb4b4b4{ Te6edf3processReceivedMeshPacketTb4b4b4(Te6edf3bufferedTb4b4b4.Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3bufferedTb4b4b4.Te6edf3sessionTb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3onFailure Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffDropped a buffered early packet after a handler error; replay continuedTa5d6ff" Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3admittedTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffDropping buffered packet from stale transport session gen=Tffd700${Te6edf3bufferedTb4b4b4.Te6edf3sessionTb4b4b4.Te6edf3generationTffd700}Ta5d6ff" Tb4b4b4}
Tb4b4b4}
Tff7b72return Te6edf3admitted
Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4)
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffprocessReceivedMeshPacketTb4b4b4(Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3myNodeNumTb4b4b4: Tffa657IntTb4b4b4, Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3decoded Tff7b72= Te6edf3packetTb4b4b4.Te6edf3decoded Tff7b72?: Tff7b72return
Tff7b72val Te6edf3log Tff7b72=
Te6edf3MeshLogTb4b4b4(
Te6edf3uuid Tff7b72= Te6edf3UuidTb4b4b4.Te6edf3randomTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3message_type Tff7b72= Ta5d6ff"Ta5d6ffPacketTa5d6ff"Tb4b4b4,
Te6edf3received_date Tff7b72= Te6edf3nowMillisTb4b4b4,
Te6edf3raw_message Tff7b72= Te6edf3packetTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4,
Te6edf3fromNum Tff7b72= Tff7b72if Tb4b4b4(Te6edf3packetTb4b4b4.Te6edf3from Tff7b72=Tff7b72= Te6edf3myNodeNumTb4b4b4) Te6edf3MeshLogTb4b4b4.Te6edf3NODE_NUM_LOCAL Tff7b72else Te6edf3packetTb4b4b4.Te6edf3fromTb4b4b4,
Te6edf3portNum Tff7b72= Te6edf3decodedTb4b4b4.Te6edf3portnumTb4b4b4.Te6edf3valueTb4b4b4,
Te6edf3fromRadio Tff7b72= Te6edf3FromRadioTb4b4b4(Te6edf3packet Tff7b72= Te6edf3packetTb4b4b4)Tb4b4b4,
Tb4b4b4)
Tff7b72val Te6edf3logJob Tff7b72= Te6edf3insertMeshLogTb4b4b4(Te6edf3logTb4b4b4, Te6edf3sessionTb4b4b4)

Te6edf3launchSessionBoundTb4b4b4(Te6edf3sessionTb4b4b4, Ta5d6ff"Ta5d6ffmesh-packet emissionTa5d6ff"Tb4b4b4) Tb4b4b4{ Te6edf3serviceStateWriterTb4b4b4.Te6edf3emitMeshPacketTb4b4b4(Te6edf3packetTb4b4b4) Tb4b4b4}

Tff7b72val Te6edf3from Tff7b72= Te6edf3packetTb4b4b4.Te6edf3from
Tff7b72if Tb4b4b4(Te6edf3from Tff7b72=Tff7b72= Te6edf3myNodeNumTb4b4b4) Tb4b4b4{
Te6edf3persistNodeUpdateTb4b4b4(
Te6edf3myNodeNumTb4b4b4,
Te6edf3channel Tff7b72= Te6edf3packetTb4b4b4.Te6edf3channelTb4b4b4,
Te6edf3operation Tff7b72= Ta5d6ff"Ta5d6fflocal sender-node packet updateTa5d6ff"Tb4b4b4,
Tb4b4b4) Tb4b4b4{ Te6edf3node Tff7b72-Tff7b72>
Te6edf3applySenderPacketUpdateTb4b4b4(Te6edf3nodeTb4b4b4, Te6edf3packetTb4b4b4, Te6edf3decodedTb4b4b4)Tb4b4b4.Te6edf3copyTb4b4b4(Te6edf3lastHeard Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3persistNodeUpdateTb4b4b4(Te6edf3myNodeNumTb4b4b4, Te6edf3operation Tff7b72= Ta5d6ff"Ta5d6fflocal-node packet refreshTa5d6ff"Tb4b4b4) Tb4b4b4{ Te6edf3nodeTb4b4b4: Te6edf3Node Tff7b72-Tff7b72>
Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3lastHeard Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Te6edf3persistNodeUpdateTb4b4b4(Te6edf3fromTb4b4b4, Te6edf3channel Tff7b72= Te6edf3packetTb4b4b4.Te6edf3channelTb4b4b4, Te6edf3operation Tff7b72= Ta5d6ff"Ta5d6ffsender-node packet updateTa5d6ff"Tb4b4b4) Tb4b4b4{ Te6edf3node Tff7b72-Tff7b72>
Te6edf3applySenderPacketUpdateTb4b4b4(Te6edf3nodeTb4b4b4, Te6edf3packetTb4b4b4, Te6edf3decodedTb4b4b4)
Tb4b4b4}
Tb4b4b4}

Te6edf3dataHandlerTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3handleReceivedDataTb4b4b4(Te6edf3packetTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3sessionTb4b4b4, Te6edf3logTb4b4b4.Te6edf3uuidTb4b4b4, Te6edf3logJobTb4b4b4)
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffapplySenderPacketUpdateTb4b4b4(Te6edf3nodeTb4b4b4: Te6edf3NodeTb4b4b4, Te6edf3packetTb4b4b4: Te6edf3MeshPacketTb4b4b4, Te6edf3decodedTb4b4b4: Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3DataTb4b4b4)Tb4b4b4: Te6edf3Node Tb4b4b4{
Tff7b72val Te6edf3viaMqtt Tff7b72= Te6edf3packetTb4b4b4.Te6edf3via_mqtt Tff7b72=Tff7b72= Tff7b72true
Tff7b72val Te6edf3isDirect Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72=Tff7b72= Te6edf3packetTb4b4b4.Te6edf3hop_limit
Tff7b72val Te6edf3updateRadioMetrics Tff7b72= Te6edf3isDirect Tff7b72&Tff7b72& Te6edf3packetTb4b4b4.Te6edf3isLoraTb4b4b4(Tb4b4b4) Tff7b72&Tff7b72& Tff7b72!Te6edf3viaMqtt
Tff7b72val Te6edf3hopsAway Tff7b72=
Tff7b72when Tb4b4b4{
Te6edf3decodedTb4b4b4.Te6edf3portnum Tff7b72=Tff7b72= Te6edf3PortNumTb4b4b4.Te6edf3RANGE_TEST_APP Tff7b72-Tff7b72> T79c0ff0
Te6edf3viaMqtt Tff7b72-Tff7b72> Tff7b72-T79c0ff1
Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72=Tff7b72= T79c0ff0 Tff7b72&Tff7b72& Tb4b4b4(Te6edf3decodedTb4b4b4.Te6edf3bitfield Tff7b72?: T79c0ff0Tb4b4b4) Tff7b72=Tff7b72= T79c0ff0 Tff7b72-Tff7b72> Tff7b72-T79c0ff1
Te6edf3packetTb4b4b4.Te6edf3hop_limit Tff7b72> Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72-Tff7b72> Tff7b72-T79c0ff1
Tff7b72else Tff7b72-Tff7b72> Te6edf3packetTb4b4b4.Te6edf3hop_start Tff7b72- Te6edf3packetTb4b4b4.Te6edf3hop_limit
Tb4b4b4}
Tff7b72return Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(
T8b949e// Packets reach here already stamped, so the fallback is unreachable by design and must stay that way:
T8b949e// a packet that just arrived SHOULD refresh lastHeard, using the phone's clock when the radio had no
T8b949e// time source. The fallback only guards a future caller that skips normalization from writing the epoch.
Te6edf3lastHeard Tff7b72= Te6edf3packetTb4b4b4.Te6edf3rxTimeOrNullTb4b4b4(Tb4b4b4)Tff7b72?.Te6edf3letTb4b4b4(Tff7b72::Te6edf3clampTimestampToNowTb4b4b4) Tff7b72?: Te6edf3nodeTb4b4b4.Te6edf3lastHeardTb4b4b4,
Te6edf3viaMqtt Tff7b72= Te6edf3viaMqttTb4b4b4,
Te6edf3lastTransport Tff7b72= Te6edf3packetTb4b4b4.Te6edf3transport_mechanismTb4b4b4.Te6edf3valueTb4b4b4,
T8b949e// A packet carrying no snr must not clobber the node's last real reading either.
Te6edf3snr Tff7b72= Tff7b72if Tb4b4b4(Te6edf3updateRadioMetricsTb4b4b4) Te6edf3packetTb4b4b4.Te6edf3snrOrNullTb4b4b4(Tb4b4b4) Tff7b72?: Te6edf3nodeTb4b4b4.Te6edf3snr Tff7b72else Te6edf3nodeTb4b4b4.Te6edf3snrTb4b4b4,
T8b949e// A packet carrying no rssi must not clobber the node's last real reading.
Te6edf3rssi Tff7b72= Tff7b72if Tb4b4b4(Te6edf3updateRadioMetricsTb4b4b4) Te6edf3packetTb4b4b4.Te6edf3rx_rssi Tff7b72?: Te6edf3nodeTb4b4b4.Te6edf3rssi Tff7b72else Te6edf3nodeTb4b4b4.Te6edf3rssiTb4b4b4,
Te6edf3hopsAway Tff7b72= Te6edf3hopsAwayTb4b4b4,
Tb4b4b4)
Tb4b4b4}

T8b949e/**
* Refreshes the local node's [Node.lastHeard] to prove the radio link is alive.
*
* Without this, [lastHeard] is only set when a [MeshPacket] arrives from another node (see
* [processReceivedMeshPacket]). On a quiet mesh the heartbeat cycle still exchanges data with the firmware (ToRadio
* heartbeat → FromRadio queueStatus every 30 s), but that data never touched [lastHeard], causing the local node to
* appear stale in the UI even though the connection is healthy.
*
* To avoid flooding the DB on high-frequency variants (log records arrive many times per second when debug logging
* is enabled), writes are throttled to at most once per [LOCAL_NODE_REFRESH_INTERVAL_MS].
*/
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffrefreshLocalNodeLastHeardTb4b4b4(Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3now Tff7b72= Te6edf3nowMillis
Tff7b72val Te6edf3sameGeneration Tff7b72= Te6edf3lastLocalNodeRefreshGeneration Tff7b72=Tff7b72= Te6edf3sessionTb4b4b4.Te6edf3generation
Tff7b72if Tb4b4b4(Te6edf3sameGeneration Tff7b72&Tff7b72& Te6edf3now Tff7b72- Te6edf3lastLocalNodeRefreshMs Tff7b72< Te6edf3LOCAL_NODE_REFRESH_INTERVAL_MSTb4b4b4) Tff7b72return

Tff7b72val Te6edf3myNum Tff7b72= Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNumTb4b4b4.Te6edf3value Tff7b72?: Tff7b72return
Tff7b72val Te6edf3persisted Tff7b72=
Te6edf3persistNodeUpdateTb4b4b4(Te6edf3myNumTb4b4b4, Te6edf3operation Tff7b72= Ta5d6ff"Ta5d6fflocal-node link refreshTa5d6ff"Tb4b4b4) Tb4b4b4{ Te6edf3nodeTb4b4b4: Te6edf3Node Tff7b72-Tff7b72>
Te6edf3nodeTb4b4b4.Te6edf3copyTb4b4b4(Te6edf3lastHeard Tff7b72= Te6edf3nowSecondsTb4b4b4.Te6edf3toIntTb4b4b4(Tb4b4b4)Tb4b4b4)
Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3persistedTb4b4b4) Tb4b4b4{
Te6edf3lastLocalNodeRefreshGeneration Tff7b72= Te6edf3sessionTb4b4b4.Te6edf3generation
Te6edf3lastLocalNodeRefreshMs Tff7b72= Te6edf3now
Tb4b4b4}
Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffpersistNodeUpdateTb4b4b4(
Te6edf3nodeNumTb4b4b4: Tffa657IntTb4b4b4,
Te6edf3channelTb4b4b4: Tffa657Int Tff7b72= T79c0ff0Tb4b4b4,
Te6edf3operationTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3transformTb4b4b4: Tb4b4b4(Te6edf3NodeTb4b4b4) Tff7b72-Tff7b72> Te6edf3NodeTb4b4b4,
Tb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72= Te6edf3safeCatching Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3updateNodeAndPersistTb4b4b4(Te6edf3nodeNumTb4b4b4, Te6edf3channelTb4b4b4, Te6edf3transformTb4b4b4) Tb4b4b4}
Tb4b4b4.Te6edf3onFailure Tb4b4b4{ Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffFailed Tffd700$Te6edf3operationTa5d6ff; packet processing continuedTa5d6ff" Tb4b4b4} Tb4b4b4}
Tb4b4b4.Te6edf3isSuccess

Tff7b72private Tff7b72fun Td2a8ffinsertMeshLogTb4b4b4(Te6edf3logTb4b4b4: Te6edf3MeshLogTb4b4b4, Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4)Tb4b4b4: Te6edf3Job Tff7b72=
Te6edf3launchSessionBoundTb4b4b4(Te6edf3sessionTb4b4b4, Ta5d6ff"Ta5d6ffmesh-log insertTa5d6ff"Tb4b4b4) Tb4b4b4{ Te6edf3meshLogRepositoryTb4b4b4.Te6edf3valueTb4b4b4.Te6edf3insertTb4b4b4(Te6edf3logTb4b4b4) Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8fflaunchSessionBoundTb4b4b4(Te6edf3sessionTb4b4b4: Te6edf3RadioSessionContextTb4b4b4, Te6edf3operationTb4b4b4: Tffa657StringTb4b4b4, Te6edf3blockTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tb4b4b4: Te6edf3Job Tff7b72=
Te6edf3scopeTb4b4b4.Te6edf3handledLaunchTb4b4b4(Te6edf3start Tff7b72= Te6edf3CoroutineStartTb4b4b4.Te6edf3UNDISPATCHEDTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3admitted Tff7b72= Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3runWithSessionLeaseTb4b4b4(Te6edf3sessionTb4b4b4) Tb4b4b4{ Te6edf3blockTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3admittedTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffSkipping Tffd700$Te6edf3operationTa5d6ff from stale transport session gen=Tffd700${Te6edf3sessionTb4b4b4.Te6edf3generationTffd700}Ta5d6ff" Tb4b4b4}
Tb4b4b4}
Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{
T8b949e/**
* Minimum interval between local-node `lastHeard` DB writes, in milliseconds. Aligned with the heartbeat
* interval (30 s) so that one write per heartbeat cycle keeps the node fresh without unnecessary DB churn.
*/
Tff7b72private Tff7b72const Tff7b72val Te6edf3LOCAL_NODE_REFRESH_INTERVAL_MS Tff7b72= T79c0ff3T79c0ff0Te6edf3_000L
Tb4b4b4}
Tb4b4b4}

Served by rngit 1.5.0 - Generated in 0.2s